package com.zhf.springboot.controller;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory;
import org.springframework.stereotype.Component;

/**
 * @author: 曾鸿发
 * @create: 2022-01-10 23:46
 * @description：
 **/
@Component
public class ConsumerReceiver {


    // 直连模式的多个消费者，会分到其中一个消费者进行消费，类似task模式
    // 通过注入RabbitContainerFactory对象，来设置一些属性，相当于task里的channel.basicQos
    @RabbitListener(queues = "helloWorldqueue")
    public void helloWorldReceive(String message){
        System.out.println("hello world 模式 received message :" + message);
    }
}
